from celery import Celery
import os

os.environ.setdefault('FORKED_BY_MULTIPROCESSING', '1')

# 1. 创建 celery 对象实例（可以创建多个应用）
app = Celery('luffy')

# 2. 加载配置（给应用对象指定任务队列以及结果队列）
app.config_from_object('mycelery.config')

# 3. 自动发现任务
app.autodiscover_tasks(['mycelery.sms', 'mycelery.email'])
